package com.jeffse.light.stream.core.data.operator.Covert;

import com.jeffse.light.stream.core.data.descriptor.operatorDescriptor.OperatorDescriptor;
import com.jeffse.light.stream.core.function.base.ProcessFunction;

public class ProcessConvert<T> implements BaseConvert<T> {
    @Override
    public void convert(OperatorDescriptor operatorDescriptor, T value) throws Exception {
        ProcessFunction processFunction = (ProcessFunction) operatorDescriptor.getFunc();
        processFunction.setNextOperatorDescriptor(operatorDescriptor.getNetOperatorDescriptor());
        processFunction.processElement((ProcessFunction)operatorDescriptor.getFunc(), value);
    }
}
